package com.qezhhnjy.flink;

import com.qezhhnjy.flink.job.StreamSensor;

/**
 * @author zhaoyangfu
 * @date 2021/8/24-16:31
 */
public class FlinkApplication {

    public static void main(String[] args) throws Exception {
        // WordCount.stream(args);
        // StreamKafka.stream(args);
        // StreamSensor.handle();
//        StreamSensor.sideOutput();
        // StreamSensor.connect();
//         StreamSensor.rich();
        // StreamSensor.sinkToFile();
        // StreamSensor.sinkToRedis();
//         StreamSensor.tumblingTimeWindow();
//         StreamSensor.slidingTimeWindow();
//        StreamSensor.sessionWindow();
        StreamSensor.countWindow();
    }

}
